package com.runjian.rundo.iot.agent.business.publisher;

import com.runjian.rundo.iot.agent.common.enums.DeviceMessageType;
import com.runjian.rundo.iot.agent.common.message.DeviceMessage;

/**
 * 设备消息处理器
 *
 * @author LiGang
 */
public interface DeviceMessageProcessor<T extends DeviceMessage> {

    /**
     * 获取消息类型
     *
     * @return DeviceMessageType
     */
    DeviceMessageType getType();

    /**
     * 处理设备消息
     *
     * @param deviceMessage DeviceMessage
     */
    void process(T deviceMessage);

}
